package com.adou.d9.tcp4;

import java.io.DataOutputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;

/**
 * tcp客户端开发
 */
public class Client {
    public static void main(String[] args) throws Exception{
        // 1.创建socket对象，并请求服务端链接
        Socket socket = new Socket("127.0.0.1", 8888);

        // D.创建一个独立的线程，不断从socket中接收服务端发过来的消息
        new ClentReadThread(socket).start();

        // 2.socket通信管道中得到字节输出流，用来发送数据到服务端程序中
        OutputStream os = socket.getOutputStream();

        // 3.把低级输出流包装成数据输出流
        DataOutputStream dos = new DataOutputStream(os);

        // 4.写数据
        Scanner sc = new Scanner(System.in);
        while (true) {
            System.out.print("请说：");

            String msg = sc.nextLine();
            if("exit".equals(msg)) {
                System.out.println("欢迎下次光临，退出成功！！！");
                dos.close();
                socket.close();
                break;
            }


            dos.writeUTF(msg);
            dos.flush();
        }
    }
}
